package com.kafkaconn.lk
import org.
object SinkToRedis {

  def main(args: Array[String]): Unit = {

    val env = StreamExecutionEnvironment.getExecutionEnvironment
    env.setParallelism(1)

    val properties = new Properties()
    properties.setProperty("bootstrap.servers", "192.168.23.51:9092")
    val kafkaSource = new FlinkKafkaConsumer[String]("order", new SimpleStringSchema, properties)
    val stream = env.addSource(kafkaSource)

  }

}
